from obs import GetObjectHeader
from obs import ObsClient
import os
import traceback

# 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
# 您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
ak = "yourak"
sk = "yoursk"
#  server填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
server = "yourserver"
# 创建obsClient实例
# 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过security_token参数指定securityToken值
obsClient = ObsClient(access_key_id=ak, secret_access_key=sk, server=server)
# 使用访问OBS
try:
    # 下载对象的附加头域
    headers = GetObjectHeader()
    # 【可选】如果对象在指定的时间后有修改，则返回对象内容，否则返回错误。
    headers.if_modified_since = 'date'
    # 下载到本地的路径,localfile为包含本地文件名称的全路径
    downloadPath = '/home/jovyan/demo.txt'
    bucketName = "jupyterbucket"
    objectKey = "Jupyter"
    # 文件下载
    resp = obsClient.getObject(bucketName, objectKey, downloadPath, headers=headers)
    # 返回码为2xx时，接口调用成功，否则接口调用失败
    if resp.status < 300:
        print('Get Object Succeeded')
        print('requestId:', resp.requestId)
        print('url:', resp.body.url)
    else:
        print('Get Object Failed')
        print('requestId:', resp.requestId)
        print('errorCode:', resp.errorCode)
        print('errorMessage:', resp.errorMessage)
except:
    print('Get Object Failed') 
    print(traceback.format_exc())